package com.boarsoft.boar.gateway.rabbitmq;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;

import com.boarsoft.message.bean.Message;
import com.boarsoft.message.core.MessageService;

@RabbitListener(queues = "queue1")
public class RabbiMQConsumer implements MessageService {
	private final Logger log = LoggerFactory.getLogger(RabbiMQConsumer.class);

	@RabbitHandler
	public void put(Message m) {
		log.info("接收消息=====》》》》》{}", m);
	}
}
